package com.devops.admin.service;

import com.devops.admin.model.KafkaTopic;
import com.baomidou.mybatisplus.extension.service.IService;
import com.devops.admin.model.TableResult;
import com.devops.admin.po.DOSBindStatusProject;
import com.devops.admin.po.KafkaTopicPo;
import com.devops.admin.vo.DOSPageVo;
import com.devops.admin.vo.KafkaTopicVo;

import java.util.List;

/**
* @author Dell
* @description 针对表【dos_kafka_topic】的数据库操作Service
* @createDate 2023-05-17 15:09:47
*/
public interface KafkaTopicService extends IService<KafkaTopic> {

    void syncKafkaTopic();
    TableResult<KafkaTopicVo> getKafkaTopicList(KafkaTopicPo kafkaTopicPo, DOSPageVo pageVo);
    Boolean createKafkaTopic(KafkaTopicPo kafkaTopicPo);
    List<KafkaTopicVo> getKafkaTopicsByProject(Integer projectId);
    KafkaTopicVo getKafkaTopicById(Integer topicId);
    Boolean relateKafkaTopicToProjects(Integer topicId, List<Integer> projectIds);
    List<DOSBindStatusProject> getProjectsBindStatusByKafkaTopicId(Integer topicId);
    Boolean updateKafkaTopicDescription(Integer topicId, String description);
}
